package com.jml.activitymq.consumer;


import javax.jms.Session;
import javax.jms.TextMessage;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class Consumer {
	int a=0;
	//这个消费者的签收不是简单的签收，没有发生异常才会签收
	//消费端抛出异常会默认自动重试
	@JmsListener(destination = "${queue}")
	public void  receive(Session session,TextMessage textMessage){
		try {
			String jmsMessageID = textMessage.getJMSMessageID();
			System.out.println("消费端消费数据："+textMessage.getText());
			//textMessage.acknowledge();
		} catch (Exception e) {
			e.printStackTrace();
			//在这里日志记录消息报文，可以采用人工补偿，或者定时job健康检查脏数据
		}
	}
}
